package com.es.demo.main;

import com.es.demo.main.kafka.KafkaServer;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.Arrays;

public class DoMain {


    public static void main(String[] args) {
        KafkaServer kafkaServer = new KafkaServer();
        kafkaServer.init("10.135.66.17:9092","canalGroup", Arrays.asList("test_xdual"));
        kafkaServer.startConsumer();
    }


}
